const http = require('http'); // 引入http模块
const { MongoClient } = require('mongodb'); // 引入MongoClient

const hostname = '127.0.0.1';
const port = 3000;
const url = 'mongodb://localhost:27017'; // MongoDB 连接 URL

// 创建web服务器
const server = http.createServer((req, res) => {
    // req为来自客户端的请求
    // res为服务应答
    res.statusCode = 200; // 设置状态码
    res.setHeader('Content-Type', 'text/plain'); // 设置响应头字段
    res.end('Hello World\n'); // 发送消息并结束本次连接
});

// 连接到MongoDB
MongoClient.connect(url, (err, client) => {
    if (err) {
        console.error('Failed to connect to MongoDB:', err);
        return;
    }

    console.log('Connected to MongoDB successfully!');

    // 获取数据库实例
    const db = client.db('vegetable'); // 数据库名称为 'vegetable'
    const collection = db.collection('vegetable'); // 集合名称也为 'vegetable'

    // 在这里可以进行数据库操作
    // 例如：插入一条数据
    const document = { name: "Carrot", color: "Orange", price: 2.5 };
    collection.insertOne(document, (err, result) => {
        if (err) {
            console.error('Failed to insert document:', err);
            return;
        }
        console.log('Document inserted successfully:', result);

        // 启动服务器
        server.listen(port, hostname, () => {
            console.log(`Server running at http://${hostname}:${port}/`); // 启动成功后输出信息
        });
    });
});